package com.lee.mq.common;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: lishuo
 * Date: 2023-10-27
 * Time: 11:33
 */

import com.lee.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 这是一个单纯的函数式接口(回调函数). 收到消息之后要处理消息时调用的方法.
 */
@FunctionalInterface
public interface Consumer {
    // 这里的方法名和参数, 也都是参考 RabbitMQ 展开的
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;

}
